d0dc597261b0b9949ecd26150cd30ef89ecc7a21,src/java/org/apache/cassandra/service/StorageProxy.java,StorageProxy,sendToHintedEndpoints,#RowMutation#Iterable#AbstractWriteResponseHandler#String#ConsistencyLevel#,751

Before Change



        if (dcGroups != null)
        {
            MessageOut<RowMutation> message = rm.createMessage();
            // for each datacenter, send the message to one node to relay the write to other replicas
            for (Map.Entry<String, Collection<InetAddress>> entry: dcGroups.entrySet())
            {

After Change


                else
                {
                    // belongs on a different server
                    if (message == null)
                        message = rm.createMessage();

                    String dc = DatabaseDescriptor.getEndpointSnitch().getDatacenter(destination);
                    // direct writes to local DC or old Cassandra versions